package org.example.inboundhandlerandoutboundhandler;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

public class TestInboundHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        // 在这里处理接收到的数据
        System.out.println("Received data: " + msg);
        // 将数据传递给下一个处理器，如果不写这段代码，那么数据流入到当前这个处理器处理之后，就不会发送给后面的处理器处理了
        ctx.fireChannelRead(msg);
    }
}
